package disruptor;

import com.lmax.disruptor.WorkHandler;
import dto.TransformDataWrapper;
import lombok.Data;

/**
 * @author ChenJunhong
 * @date 2018/12/16
 * Description:
 */
@Data
public abstract class AbstractMessageConsumer implements WorkHandler<TransformDataWrapper> {

    protected String consumerId;

    public AbstractMessageConsumer(String consumerId) {
        this.consumerId = consumerId;
    }
}
